//package com.project.stream_consumer.demo4.controller;
//
//import org.springframework.cloud.stream.annotation.EnableBinding;
//import org.springframework.cloud.stream.annotation.StreamListener;
//import org.springframework.cloud.stream.messaging.Sink;
//import org.springframework.messaging.Message;
//import org.springframework.stereotype.Component;
//
//@Component
//@EnableBinding(Sink.class)
//public class ConsunmerController {
//    @StreamListener(Sink.INPUT)
//    public void input(Message<String> message){
//        System.out.println(Thread.currentThread().getName()+"消费消息:"+message.getPayload());
//    }
//}
